//package com.example.actordemo1.io;
//
//import akka.actor.AbstractActor;
//import akka.actor.ActorRef;
//import akka.actor.ActorSystem;
//import akka.actor.Props;
//import akka.io.Tcp;
//import akka.io.TcpMessage;
//import akka.util.ByteString;
//
//public class SimplisticHandler extends AbstractActor {
//    @Override
//    public Receive createReceive() {
//        return receiveBuilder()
//                .match(
//                        Tcp.Received.class,
//                        msg -> {
//                            final ByteString data = msg.data();
//                            System.out.println(data);
//                            getSender().tell(TcpMessage.write(data), getSelf());
//                        })
//                .match(
//                        Tcp.ConnectionClosed.class,
//                        msg -> {
//                            getContext().stop(getSelf());
//                        })
//                .build();
//    }
//
//    public static void main(String[] args) {
//        ActorSystem actorSystem = ActorSystem.create("sys");
//        ActorRef actorRef = actorSystem.actorOf(Props.create(SimplisticHandler.class), "simplisticHandler");
//    }
//}